package com.bjsxt.spark.areaRoadFlow

import org.apache.spark.{SparkConf, SparkContext}

object lskCustomAna {



  def main(args: Array[String]): Unit = {
    val conf = new SparkConf()
    conf.setAppName("map").setMaster("local")
    val sc = new SparkContext(conf)
    val infos = sc.parallelize(Array[String]("hello spark","hello hdfs","hello hive"))


    val result = infos.map(one=>{
      one.split(" ")
    })
    result.foreach( k=> {
      k.foreach(println)
    } )
  }
}
